package api.beans;

import java.io.Serializable;

/**
 * 对应 错误数据记录表 bdip_flink_errordata
 */
public class ErrorSinkData implements Serializable {

    private static final long serialVersionUID = 1L;

    String id; //主键ID
    String taskId; //实时任务id
    String taskName; //实时任务名称
    String basicTableId; //表id
    String basicTableName; //表名
    String kafkaOffset; //offset:kafka源该字段才有值
    String sourceType; //kafka,file,interface
    String dsId; //数据源id
    String errorData; //错误数据
    String storageTime; //入库时间
    String oDate; //数据日期:yyyy-MM-dd

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getTaskId() {
        return taskId;
    }

    public void setTaskId(String taskId) {
        this.taskId = taskId;
    }

    public String getTaskName() {
        return taskName;
    }

    public void setTaskName(String taskName) {
        this.taskName = taskName;
    }

    public String getBasicTableId() {
        return basicTableId;
    }

    public void setBasicTableId(String basicTableId) {
        this.basicTableId = basicTableId;
    }

    public String getBasicTableName() {
        return basicTableName;
    }

    public void setBasicTableName(String basicTableName) {
        this.basicTableName = basicTableName;
    }

    public String getKafkaOffset() {
        return kafkaOffset;
    }

    public void setKafkaOffset(String kafkaOffset) {
        this.kafkaOffset = kafkaOffset;
    }

    public String getSourceType() {
        return sourceType;
    }

    public void setSourceType(String sourceType) {
        this.sourceType = sourceType;
    }

    public String getDsId() {
        return dsId;
    }

    public void setDsId(String dsId) {
        this.dsId = dsId;
    }

    public String getErrorData() {
        return errorData;
    }

    public void setErrorData(String errorData) {
        this.errorData = errorData;
    }

    public String getStorageTime() {
        return storageTime;
    }

    public void setStorageTime(String storageTime) {
        this.storageTime = storageTime;
    }

    public String getoDate() {
        return oDate;
    }

    public void setoDate(String oDate) {
        this.oDate = oDate;
    }
}
